package com.miaow.common;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 *
 * @author hwz
 * @description  创建一个消费者
 * @date  2023/12/20 15:53
*/
public interface MyConsumer {

    String INPUT = "input";

    @Input(INPUT)
    SubscribableChannel input();
}
